package org.alex.mqtt.common.bus;

import org.alex.mqtt.common.bus.model.DeviceSession;

/**
 * session管理器
 * @author : alex
 */
public interface DeviceSessionManager {
    /**
     * 获取session
     */
    DeviceSession getSession(String clientId);

    /**
     * 存储seesion
     */
    void storeSeesion(DeviceSession deviceSession);

    /**
     * 离线
     */
    void offline(String  clientId);
}
